package cn.doitedu.day07

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.6
 * @Created by HANGGE
 * @Description
 */
object C02_累加器 {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
   // 创建RDD
    val rdd = sc.makeRDD(Array(1, 2, 3, 4, 5, 6))
    var  cnt = 0
    //转换算子
    val rdd2 = rdd.map(e=>{
      // 累加
      cnt += 1
      e
    })
    // 执行行动算子
    rdd2.foreach(println)
    // 打印结果
    println(cnt)  // 0  没有执行行动算子   函数没有触发



  }

}
